//package com.mbyte.easy.rabbitMQ;
//
//import com.mbyte.easy.config.RabbitMQConfig;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.stereotype.Service;
//
///**
// * @author zte
// * @since 2021/1/20 22:19
// */
//@Slf4j
//@Service
//public class MQReceiver {
//
//    /**
//     * 简单模式
//     * @param msg
//     */
//    @RabbitListener(queues = "queue")
//    public void receive(Object msg){
//        log.info("接收消息：" + msg);
//    }
//
//    /**
//     * Fanout模式
//     * @param msg
//     */
//    @RabbitListener(queues = RabbitMQConfig.QUEUE_ONE)
//    public void receiveOne(Object msg){
//        log.info("接收消息：" + msg);
//    }
//
//    @RabbitListener(queues = RabbitMQConfig.QUEUE_TWO)
//    public void receiveTwo(Object msg){
//        log.info("接收消息：" + msg);
//    }
//
//    /**
//     * Topic 模式
//     * @param msg
//     */
//    @RabbitListener(queues = RabbitMQConfig.TOPIC_QUEUE_ONE)
//    public void receiveTopicOne(Object msg){
//        log.info("接收消息：{}",msg);
//    }
//    @RabbitListener(queues = RabbitMQConfig.TOPIC_QUEUE_TWO)
//    public void receiveTopicTwo(Object msg){
//        log.info("接收消息：{}",msg);
//    }
//
//}
